package com.qiguliuxing.dts.job.listener;

import com.dangdang.ddframe.job.executor.ShardingContexts;
import com.dangdang.ddframe.job.lite.api.listener.ElasticJobListener;
import org.slf4j.Logger;

import static org.slf4j.LoggerFactory.getLogger;

/**
 * 定义一个通用的job监听类
 * @author qiguliuxing
 * @since 1.0.0
 */
public class JobListener implements ElasticJobListener {

    private static final Logger logger = getLogger(JobListener.class);
    /**
     * 作业执行前的执行的方法.
     *
     * @param shardingContexts 分片上下文
     */
    @Override
    public void beforeJobExecuted(ShardingContexts shardingContexts) {
        logger.info("调度 JOB: [" + shardingContexts.getJobName() + "] 开始执行");
    }

    /**
     * 作业执行后的执行的方法.
     *
     * @param shardingContexts 分片上下文
     */
    @Override
    public void afterJobExecuted(ShardingContexts shardingContexts) {
        logger.info("调度 JOB: [" + shardingContexts.getJobName() + "]结束");
    }
}
